Node / ReticulumProjects / MeshChatX.git / files / meshchatx / src / backend / database / voicemails.py

Displaying Raw • Download

Tff7b72from T7ee787.T7ee787provider Tff7b72import Te6edf3DatabaseProvider

Tff7b72class T56d364VoicemailDAOTb4b4b4:

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3providerTb4b4b4: Te6edf3DatabaseProviderTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffprovider Tff7b72= Te6edf3provider

Tff7b72def Td2a8ffadd_voicemailTb4b4b4(

Tff7b72selfTb4b4b4,

Te6edf3remote_identity_hashTb4b4b4,

Te6edf3remote_identity_nameTb4b4b4,

Te6edf3filenameTb4b4b4,

Te6edf3duration_secondsTb4b4b4,

Te6edf3timestampTb4b4b4,

Tb4b4b4)Tb4b4b4:

Tff7b72from T7ee787datetime Tff7b72import Te6edf3UTCTb4b4b4, Te6edf3datetime

Te6edf3now Tff7b72= Te6edf3datetimeTff7b72.Td2a8ffnowTb4b4b4(Te6edf3UTCTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffproviderTff7b72.Td2a8ffexecuteTb4b4b4(

T8b949e"""

INSERT INTO voicemails (

remote_identity_hash,

remote_identity_name,

filename,

duration_seconds,

timestamp,

created_at

) VALUES (?, ?, ?, ?, ?, ?)

"""Tb4b4b4,

Tb4b4b4(

Te6edf3remote_identity_hashTb4b4b4,

Te6edf3remote_identity_nameTb4b4b4,

Te6edf3filenameTb4b4b4,

Te6edf3duration_secondsTb4b4b4,

Te6edf3timestampTb4b4b4,

Te6edf3nowTb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffget_voicemailsTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3limitTff7b72=T79c0ff50Tb4b4b4, Te6edf3offsetTff7b72=T79c0ff0Tb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffproviderTff7b72.Td2a8fffetchallTb4b4b4(

Ta5d6ff"Ta5d6ffSELECT * FROM voicemails ORDER BY timestamp DESC LIMIT ? OFFSET ?Ta5d6ff"Tb4b4b4,

Tb4b4b4(Te6edf3limitTb4b4b4, Te6edf3offsetTb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffget_voicemailTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3voicemail_idTb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffproviderTff7b72.Td2a8fffetchoneTb4b4b4(

Ta5d6ff"Ta5d6ffSELECT * FROM voicemails WHERE id = ?Ta5d6ff"Tb4b4b4,

Tb4b4b4(Te6edf3voicemail_idTb4b4b4,Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffmark_as_readTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3voicemail_idTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffproviderTff7b72.Td2a8ffexecuteTb4b4b4(

Ta5d6ff"Ta5d6ffUPDATE voicemails SET is_read = 1 WHERE id = ?Ta5d6ff"Tb4b4b4,

Tb4b4b4(Te6edf3voicemail_idTb4b4b4,Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffdelete_voicemailTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3voicemail_idTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffproviderTff7b72.Td2a8ffexecuteTb4b4b4(

Ta5d6ff"Ta5d6ffDELETE FROM voicemails WHERE id = ?Ta5d6ff"Tb4b4b4,

Tb4b4b4(Te6edf3voicemail_idTb4b4b4,Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8ffget_unread_countTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3row Tff7b72= Tff7b72selfTff7b72.Td2a8ffproviderTff7b72.Td2a8fffetchoneTb4b4b4(

Ta5d6ff"Ta5d6ffSELECT COUNT(*) as count FROM voicemails WHERE is_read = 0Ta5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72return Te6edf3rowTb4b4b4[Ta5d6ff"Ta5d6ffcountTa5d6ff"Tb4b4b4] Tff7b72if Te6edf3row Tff7b72else T79c0ff0